package com.blyat.xsoft.kernel.component.mq;

import org.apache.rocketmq.client.consumer.listener.MessageListener;

import java.util.List;

/**
 * @Auther: syh
 * @Date: 2020/8/7
 * @Description:
 */
public interface MQConsumer<T> extends MessageListener {
    void consume(List<T> list) throws Exception;
}
